adbe8850f5e14dae21bb65e53586048b6bc3f2dd,cdap-app-templates/cdap-etl/cdap-data-pipeline/src/test/java/co/cask/cdap/datapipeline/DataPipelineTest.java,DataPipelineTest,testPipelineWithActions,#,105

Before Change


      .addConnection("source", "sink")
      .addConnection("action1", "action2")
      .addConnection("action2", "source")
      .addConnection("sink", "action3")
      .build();

    AppRequest<ETLBatchConfig> appRequest = new AppRequest<>(APP_ARTIFACT, etlConfig);
    Id.Application appId = Id.Application.from(Id.Namespace.DEFAULT, "MyApp");

After Change


      .addConnection(sourceName, sinkName)
      .addConnection("action1", "action2")
      .addConnection("action2", sourceName)
      .addConnection(sinkName, "action3")
      .setEngine(engine)
      .build();

    AppRequest<ETLBatchConfig> appRequest = new AppRequest<>(APP_ARTIFACT, etlConfig);